package cz.cvut.fel.riak.loader;

import java.io.IOException;

public abstract class Persister extends Thread {
	protected String server;
	protected Integer port;
	
	public Persister(String server, Integer port) {
		super();
		this.server = server;
		this.port = port;
	}
	
	public abstract void connect() throws Exception;
	
	//public abstract void store(byte[] data) throws Exception;
	
	public abstract void disconnect();

	public abstract void store(String key, byte[] data) throws Exception;
}
